package user;

import model.Pipeline;
import interfaces.PipelineI;

public class PipeDemo {

	/**
	 * @param args
	 */
	public static void main(String[] args) {

		PipelineI pipe1 = new Pipeline();
		pipe1.setWorkers(3);
		// pipe1.setTask(0, new TaskReadText("../Pipe/src/wortlist.txt"));
		// pipe1.setTask(1, new TaskToUpper());
		// pipe1.setTask(2, new TaskOutputText(System.out));
		pipe1.appendTask(new TaskReadText("../Pipe/src/wortlist.txt"));
		pipe1.appendTask(new TaskToUpper());
		pipe1.appendTask(new TaskOutputText(System.out));
		pipe1.excute();
		pipe1.allStop();

	}

}
